70c2144e2054f42567107310c0205cd73a85dc07,src/main/java/reactor/core/publisher/FluxPublish.java,State,onNext,#T#,215
Before Change
}
if (!queue.offer(t)) {
Throwable ex = Exceptions.failWithOverflow("Queue full?!");
if (!Exceptions.addThrowable(ERROR, this, ex)) {
Operators.onErrorDropped(ex);
return;
After Change
}
if (!queue.offer(t)) {
Throwable ex = Operators.onOperatorError(s, Exceptions.failWithOverflow("Queue is full?!"), t);
if (!Exceptions.addThrowable(ERROR, this, ex)) {
Operators.onErrorDropped(ex);
return;